package com.xiashitech.apiservice.grpc;

import com.xiashitech.interfaces.grpc.RPCUserInfoRequest;
import com.xiashitech.interfaces.grpc.RPCUserInfoResponse;
import com.xiashitech.interfaces.grpc.RPCUserServiceGrpc;
import io.grpc.stub.StreamObserver;
import lombok.extern.slf4j.Slf4j;
import net.devh.boot.grpc.server.service.GrpcService;
import org.springframework.stereotype.Service;

@Slf4j
//@Service
@GrpcService
public class UserInfoService extends RPCUserServiceGrpc.RPCUserServiceImplBase {
    @Override
    public StreamObserver<RPCUserInfoRequest> biStreamUserInfo(StreamObserver<RPCUserInfoResponse> responseObserver) {
        // 目前没用，可不实现
        log.info("biStreamUserInfo enter......");
        return super.biStreamUserInfo(responseObserver);
    }

}
